package com.wxw.tools;

import org.springframework.beans.factory.annotation.Autowired;

import com.wxw.controller.GroupChatController;

public class RecMqttWork {
	
	@Autowired
    GroupChatController groupChatController;
	@Autowired
	MyMQTTClient myMQ;
	
	public void RecMqttWork(String topic,String content) {
		
		System.out.println(topic+"---------------"+content);

			groupChatController.onMessage("A01",topic,content);

			myMQ.publish(content, topic);
			
			
			
	}
}
